package org.datastreamapi.read

import org.FlinkStreamApp
import org.apache.flink.streaming.api.scala._
import org.diysource.SensorSource

/**
 * description ：自定义数据源读取
 * author      ：剧情再美终是戏 
 * mail        : 13286520398@163.com
 * date        ：Created in 2020/2/21 19:33
 * modified By ：
 * version:    : 1.0
 */
object ReadDiy extends FlinkStreamApp {

  override def doSomeThing(environment: StreamExecutionEnvironment) = {
    environment.addSource(new SensorSource).print
  }

}
